getMessagesFlowInternal

open fun getMessagesFlowInternal(currentTimestamp: String): Flow<List<MessageEntity>>